package br.edu.fateczl.dao;

import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import javax.swing.JOptionPane;

import br.edu.fateczl.model.Funcionario;
import br.edu.fateczl.model.Usuario;

public class UsuarioDAO {
	Connection c;

	public UsuarioDAO() {
		GenericDAO gDao = new GenericDAO();
		c = gDao.getConnection();
	}

	public boolean insereUsuario(Usuario usuario) {
		boolean inserido = false;
		String sql = "INSERT INTO usuario (usuario,senha) VALUES (?,?)";

		try {
			PreparedStatement ps = c.prepareStatement(sql);
			ps.setString(1, usuario.getUsuario());
			ps.setString(2, usuario.getSenha());
			ps.execute();
			ps.close();
			inserido = true;
		} catch (SQLException e) {
			JOptionPane.showMessageDialog(null, e.getMessage(), "Erro",
					JOptionPane.ERROR_MESSAGE);
		}
		return inserido;
	}

	public boolean atualizaUsuario(Usuario usuario) {
		boolean atualizado = false;
		String sql = "UPDATE usuario Set usuario = ?,senha = ? WHERE codigo = ?";
		try {
			PreparedStatement ps = c.prepareStatement(sql);

			ps.setString(1, usuario.getUsuario());
			ps.setString(2, usuario.getSenha());
			ps.setInt(3, usuario.getCodigo());
			ps.execute();
			ps.close();
			atualizado = true;
		} catch (SQLException e) {
			JOptionPane.showMessageDialog(null, e.getMessage(), "Erro",
					JOptionPane.ERROR_MESSAGE);
		}
		return atualizado;

	}

	public boolean excluiUsuario(Usuario usuario) {
		boolean excluido = false;
		String sql = "DELETE usuario WHERE codigo = ?";
		try {
			PreparedStatement ps = c.prepareStatement(sql);
			ps.setInt(1, usuario.getCodigo());
			ps.execute();
			ps.close();
			excluido = true;
		} catch (SQLException e) {
			JOptionPane.showMessageDialog(null, e.getMessage(), "Erro",
					JOptionPane.ERROR_MESSAGE);
		}
		return excluido;
	}

	public Usuario consultaUsuario(Usuario usuario) {
		Usuario usuarioConsultado = new Usuario();
		String sql = "SELECT codigo,usuario,senha FROM usuario Where codigo = ?";
		try {
			PreparedStatement ps = c.prepareStatement(sql);
			ps.setInt(1, usuario.getCodigo());
			ResultSet rs = ps.executeQuery();
			if (rs.next()) {

				usuarioConsultado.setCodigo(rs.getInt("codigo"));
				usuarioConsultado.setUsuario(rs.getString("usuario"));
				usuarioConsultado.setSenha(rs.getString("senha"));

			}
			rs.close();
			ps.close();
		} catch (SQLException e) {
			JOptionPane.showMessageDialog(null, e.getMessage(), "Erro",
					JOptionPane.ERROR_MESSAGE);
		}
		return usuarioConsultado;
	}

	public List<Usuario> consultaListaUsuario() {
		List<Usuario> listaUsuario = new ArrayList<Usuario>();
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT codigo,usuario,senha");
		sql.append(" FROM usuario");
		try {
			PreparedStatement ps = c.prepareStatement(sql.toString());
			ResultSet rs = ps.executeQuery();
			while (rs.next()) {

				Usuario usuarioConsultado = new Usuario();
				usuarioConsultado.setCodigo(rs.getInt("codigo"));
				usuarioConsultado.setUsuario(rs.getString("usuario"));
				usuarioConsultado.setSenha(rs.getString("senha"));

				listaUsuario.add(usuarioConsultado);
			}
			rs.close();
			ps.close();
		} catch (SQLException e) {
			JOptionPane.showMessageDialog(null, e.getMessage(), "Erro",
					JOptionPane.ERROR_MESSAGE);
		}
		return listaUsuario;
	}

	public int selecionarUltimoUsuario() throws SQLException {
		String sql = "select max(codigo) as codigo from usuario";
		Connection con = GenericDAO.getConnection();
		PreparedStatement prepare = con.prepareStatement(sql);
		ResultSet result = prepare.executeQuery();
		int codigo = 0;

		while (result.next()) {
			codigo = result.getInt("codigo");
		}

		return codigo;
	}

}
